# celery启动文件
from celery import Celery

# 为celery使用django配置文件进行设置
import os
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "mall.settings")

# 创建celery实例 参数为实例名字
celery_app = Celery('celery_tasks')

#设置broker(生产者),通过加载配置文件设置broker
celery_app.config_from_object('celery_tasks.config')

#需要celery自动检测指定包的任务,列表中的元素是tasks的路径
celery_app.autodiscover_tasks(['celery_tasks.sms','celery_tasks.email'])

# 消费者 celery -A celery_tasks.main worker -l INFO -P eventlet执行这个指令
# celery_tasks.main是celery实例的路径,需要安装库pip install eventlet